package com.zzy.threaddemo;

import com.google.common.util.concurrent.RateLimiter;

public class RateLimiterTest {

	public void  testThread(){
		RateLimiter limiter = RateLimiter.create(4.0); //每秒不超过4个任务被提交
		//limiter.acquire();  //请求RateLimiter, 超过permits会被阻塞
		//也可以以非阻塞的形式来使用：
		if(limiter.tryAcquire()){ //未请求到limiter则立即返回false
		   // doSomething();
		}else{
		   // doSomethingElse();
		}
		
	}

}
